rop: RoP 将 RocketMQ 协议处理插件引入 Pulsar broker,这样 Pulsar 就能支持原生 RocketMQ 协议了。 | 您所在的位置:网站首页 › pulsar protocol › rop: RoP 将 RocketMQ 协议处理插件引入 Pulsar broker,这样 Pulsar 就能支持原生 RocketMQ 协议了。 |
RoP stands for RocketMQ on Pulsar. Rop broker supports RocketMQ-4.6.1 protocol, and is backed by Pulsar. RoP is implemented as a Pulsar ProtocolHandler with protocol name "rocketmq". ProtocolHandler is build as a nar file, and is loaded when Pulsar Broker starts. RoP is implemented based on Pulsar features. Currently, the functions supported by RoP are as follows: Send and Receive Messages SendAsync Messages Queue Selector Producer Round Robin Producer Producer And Consumer(Push and Pull) With Namespace Batch Messages Order Messages Send And Receive With Tag Deliver Level Message Retry Topic DLQ Topic Broadcast Consumer Get startedIn this guide, you will learn how to use the Pulsar broker to serve requests from RocketMQ client. Download PulsarDownload Pulsar 2.7.1 binary package apache-pulsar-2.7.1-bin.tar.gz. and unzip it. Note: Currently, RoP is only compatible with Apache Pulsar 2.7.0 and above. Download and Build RoP PluginYou can download rop nar file from the RoP sources. To build from code, complete the following steps: Clone the project from GitHub to your local. git clone https://github.com/streamnative/rop.git cd rop Build the project. mvn clean install -DskipTestsYou can find the nar file in the following directory. ./target/pulsar-protocol-handler-rocketmq-${version}.nar Configuration Name Description Default rocketmqTenant RocketMQ on Pulsar broker tenant rocketmq rocketmqMetadataTenant The tenant used for storing Rocketmq metadata topics rocketmq rocketmqNamespace Rocketmq on Pulsar Broker namespace default rocketmqMetadataNamespace The namespace used for storing rocket metadata topics __rocketmq rocketmqListeners RocketMQ service port rocketmq://127.0.0.1:9876 rocketmqMaxNoOfChannels The maximum number of channels which can exist concurrently on a connection 64 rocketmqMaxFrameSize The maximum frame size on a connection 4194304 (4MB) rocketmqHeartBeat The default heartbeat timeout of RoP connection 60 (s) Configure Pulsar broker to run RoP protocol handler as PluginAs mentioned above, RoP module is loaded with Pulsar broker. You need to add configs in Pulsar's config file, such as broker.conf or standalone.conf. Protocol handler configurationYou need to add messagingProtocols(the default value is null), protocolHandlerDirectory ( the default value is "./protocols") and loadManagerClassName=org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl, in Pulsar configuration files, such as broker.conf or standalone.conf. For RoP, the value for messagingProtocols is rocketmq; the value for protocolHandlerDirectory is the directory of RoP nar file. The following is an example. messagingProtocols=rocketmq protocolHandlerDirectory=./protocols loadManagerClassName=org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl Set RocketMQ service listenersSet RocketMQ service listeners. Note that the hostname value in listeners is the same as Pulsar broker's advertisedListeners. The following is an example. rocketmqListeners=rocketmq://127.0.0.1:9876 advertisedListeners=INTERNAL:pulsar://127.0.0.1:6650,INTERNAL:pulsar+ssl://127.0.0.1:6651,INTERNAL_ROP:pulsar://127.0.0.1:9876,INTERNAL_ROP:pulsar+ssl://127.0.0.1:9896 rocketmqListenerPortMap=9876:INTERNAL_ROP Set offset management as below since offset management for RoP depends on Pulsar "Broker Entry Metadata". It’s required for KoP 2.8.0 or higher version. brokerEntryMetadataInterceptors=org.apache.pulsar.common.intercept.AppendIndexMetadataInterceptor Set brokerDeleteInactiveTopicsEnabled to false. brokerDeleteInactiveTopicsEnabled=falseNote: advertisedListeners and advertisedAddress cannot be configured at the same time. Run Pulsar brokerWith the above configuration, you can start your Pulsar broker. For details, refer to Pulsar Get started guides. cd apache-pulsar-2.7.1 bin/pulsar standalone -nss -nfw Run RocketMQ Client to verifyIn the RoP repo, we provide a sub model of examples, which contains a variety of scenarios used by the rocketmq client. You can run these examples directly in the IDE. Or you can download the RocketMQ src code and run RocketMQ client of examples. Log level configurationIn Pulsar log4j2.yaml config file, you can set RoP log level. The following is an example. Logger: - name: RocketMQProtocolHandler level: debug additivity: false AppenderRef: - ref: Console LicenseThis library is licensed under the terms of the Apache License 2.0 and may include packages written by third parties which carry their own copyright notices and license terms. About StreamNativeFounded in 2019 by the original creators of Apache Pulsar, StreamNative is one of the leading contributors to the open-source Apache Pulsar project. We have helped engineering teams worldwide make the move to Pulsar with StreamNative Cloud, a fully managed service to help teams accelerate time-to-production. |
CopyRight 2018-2019 实验室设备网 版权所有 |